from kafka import KafkaConsumer
import json
# 1.创建KafkaConsumer连接实例，topic为newUser
consumer = KafkaConsumer(
    "newUser",
    # 本地Kafka服务器的9092默认端口
    bootstrap_servers=['127.0.0.1:9092']
)
# 2. 获取到的消费数据，并输出。
for data in consumer:
    	user = json.loads(data.value)
    	print('用户名：', user['username'])
    	print('密码：', user['password'])
    	print('手机号码：', user['mobile'])
    	print('性别：', user['gender'])
    	print('创建时间：', user['createTime'])